local _OBJ = {}
_OBJ.pool = {}

--连接redis
function _OBJ.redis(self)
    local redis_client = nil
    local redis = require("frame.redis")
    local redis_conf = config["redis"]
    if self.pool["redis"] ==nil then
        redis_client = redis:new()
        redis_client:set_timeout(1000)
        local ok, err = redis_client:connect(redis_conf["host"], redis_conf["port"])
        if not ok then
            return false
        end
        if redis_conf["pass"] ~= "" then
            local res, err = redis_client:auth(redis_conf["pass"])
            if not res then
                return false
            end
        end
        self.pool["redis"] = redis_client
    end

    return self.pool["redis"]
end

--清理工厂产生的对象(使用对象方法)
function _OBJ.destruct(self)
    --ngx.say(self.pool["redis"]:get("test1"))

    for i, v in pairs(self.pool) do
        local ok, err = v:close()
        if not ok then
            return false
        end
    end
end

return _OBJ